from celery.result import AsyncResult
from celery_test.celery1 import app

# 查看任务执行结果

asy = AsyncResult(id="f83c7113-9086-4418-9a50-3b7e164c98c4",app=app)

if asy.successful():
    result = asy.get()
    print(result)
elif asy.failed():
    print("执行失败")
elif asy.status == 'PENDING':
    print("任务等待中被执行")
elif asy.status == 'RETRY':
    print("任务异常后正在重试")
elif asy.status == 'STARTED':
    print("任务已经开始被执行")


'''
执行 add_task.py，添加任务，并获取任务ID

执行 run.py ，或者执行命令：celery worker -A celery1 -l info

执行 result.py,检查任务状态并获取结果

'''